package cn.lyjuan.aliyun.mq.conf.java.conf;

/**
 * Created by chad on 2016/11/9.
 */
public abstract class AMQUser implements IMQUser
{
    /**
     * MQ访问控制
     */
    protected MQAuthCst mqAuthCst;
    /**
     * 生产者配置
     */
    protected MQUserCst mqUserCst;


    @Override
    public void setMQAuthCst(MQAuthCst mqAuthCst)
    {
        this.mqAuthCst = mqAuthCst;
    }

    @Override
    public void setMQUserCst(MQUserCst mqUserCst)
    {
        this.mqUserCst = mqUserCst;
    }

    @Override
    public String getUserId()
    {
        return this.mqUserCst.getUserId();
    }

    @Override
    public String getTopicId()
    {
        return this.mqUserCst.getTopicId();
    }

    @Override
    public String getMsgTag()
    {
        return this.mqUserCst.getMsgTag();
    }

    @Override
    public void prepare()
    {
        // 前置任务
    }

}
